package com.gandong8.trace.tool.config.rocketmq.properties;

import lombok.Data;

/**
 rocketmq.consumer.groupName=test
 rocketmq.consumer.namesrvAddr=localhost:9876
 rocketmq.consumer.fromWhere=latest
 rocketmq.consumer.threadMin=1
 rocketmq.consumer.threadMax=2
 rocketmq.consumer.batchMaxSize=2
 */
@Data
public class RocketMqConsumerCommonData {
    protected String groupName = "test";
    protected String namesrvAddr;
    protected String fromWhere = "latest";
    protected String topics;
    protected Integer threadMin = 1;
    protected Integer threadMax = 2;
    protected Integer batchMaxSize = 2;
}
